package com.exmaple.cdc.service;

import com.exmaple.cdc.wrap.BinlogObj;

import java.io.Serializable;
import java.util.Date;
import java.util.List;
import java.util.Map;

public interface SysMQService {

    public int publish(String modelName, Serializable modelId, String table, String context);

    public void commitObj(BinlogObj binlogObj);

    public void rollBackObj(BinlogObj binlogObj);

    public int commit(String table, Long id);

    public int rollBack(String table, Long id);

    public int rollBack(String table, Long id, int retryCount, Date retryTime);

    public List<Map<String, Object>> queryList(String table, String status);

    public Map<String, Object> queryById(String table, Long id);

    public boolean isCommit(BinlogObj binlogObj);

    public boolean isCommit(String table, Long id);
}